package com.rxyb.rabbitmq.consumer;

import com.rxyb.rabbitmq.config.QueueConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;

/**
 * @author YJH
 * @version 1.0
 * @description
 * @date 2020/6/3  18:04
 */
public abstract class LogCustomerAccept implements ICustomerAccept {

    /**
     * 消费接收者
     *
     * @param json
     */
    @Override
    @RabbitListener(queues = QueueConfig.MY_LOG)
    public void accepet(String json) {
        System.out.println(json);
    }
}
